package com.qf.listener;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;

/**
 * projectName:temp_shop
 * author:luo
 * time:2023/3/14 21:23
 * 自定义一个监听器
 */
//@Component
//@RabbitListener(queues = {"queue1"})//监听器注解
public class RabbitMQListener {
    /**
     * 接收监听到的消息
     * Message:消息类型的一个对象
     * 1、消息属性
     *  一大堆属性(消息ID) 唯一 消息的标识
     *  一大堆消息头
     *
     * 2、消息体（消息本身）
     * 投递的消息内容
     */
    @RabbitHandler
    public void receiverMessage(Message message, Map map, Channel channel){
        System.out.println("接收到消息"+map);
//        byte[] body = message.getBody();
//        String s = new String(body);
//        System.out.println("接收到消息"+s);
    }

}
